package event

import (
	"github.com/sirupsen/logrus"
)

// 事件处理函数
type Handler func(msg *PbEventMessage) error

// 事件监听者
type Listener interface {
	// 设置日志引擎
	SetLogger(logger logrus.Logger)

	// @param queueName 监听的队列名
	// @param group 事件处理组，同 group 对于同一个事件只处理一次
	// @param handler 事件处理函数
	Listen(queueName, group string, handler Handler)
}
